package com.ienglish.batch.data.sqoop.service;/**
 * @description:
 * Author: wsy
 * Date: 2021/10/15 16:56
 * Content:
 */

import com.ienglish.batch.data.sqoop.entity.sqoopBean;

/**
 * @program: english-batch-data-sqoop
 *
 * @description:
 *
 * @author: ShiY.WANG
 *
 * @create: 2021-10-15 16:56
 **/


public interface SqoopService {
    /**
     * mysql到hdfs
     * @param connect
     * @param driver
     * @param username
     * @param password
     * @param table
     * @param m
     * @param targetdir
     * @param hdfsAddr
     * @return
     * @throws Exception
     */
    public sqoopBean mysqlTohdfs(String connect, String driver, String username, String password, String table, int m, String targetdir, String hdfsAddr) throws Exception;

    /**
     * mysql到hbase
     * @param jdbc
     * @param driver
     * @param username
     * @param password
     * @param mysqlTable
     * @param hbaseTableName
     * @param columnFamily
     * @param rowkey
     * @param m
     * @return
     * @throws Exception
     */
    public sqoopBean mysql2Hbase(String jdbc, String driver, String username, String password, String mysqlTable, String hbaseTableName, String columnFamily, String rowkey, int m) throws Exception;


}

